package org.bongo.open.cumulo.procengine.broker;

import org.bongo.open.cumulo.core.message.MessageUnit;

public class RoundRobinPartitioner implements ProcEnginePartitioner {

	private int lastRunnerIndex = -1;
	private int maxRunnerCount = 3;
	
	public int getPartition(MessageUnit<?> message) {
		lastRunnerIndex = (++lastRunnerIndex) % maxRunnerCount;
		return lastRunnerIndex;
	}

}
